package com.cailu.receiver.config;

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

import com.cailu.common.constant.SenderConfDirectExchangeCommon;

/**
 * @author cailu
 * @filename SenderConfDirectExchangeReceiver
 * @description 广播模式 Direct Exchange 路由
 * @date 2020/3/31 21:01
 */
@Component
public class SenderConfDirectExchangeReceiver {

	@RabbitListener(queues = SenderConfDirectExchangeCommon.DIRECT_QUEUE_A)
	public void processQueue(String str) {
		System.out.println(SenderConfDirectExchangeCommon.DIRECT_QUEUE_A + "：=============" + str.toString());
	}

}
